package xzx.service;

import reactor.core.publisher.Flux;
import xzx.bean.ChatEntity;

public interface IChatService {
    Flux<String> chatTest1(String message);

    void doChat(ChatEntity chatEntity);

    Flux<String> doChatTest1(String message,Long chatId);
}
